home *** CD-ROM | disk | FTP | other *** search
/ InfoMagic Internet Tools 1995 April / Internet Tools.iso / applic / ntp / depredated / ntp.3.4 / patches / patch4.Z / patch4
Encoding:
Text File  |  1991-09-29  |  36.1 KB  |  1,389 lines
  1. System: ntp version 3.4
  2. Patch #: 4
  3. Priority: 
  4. Subject:
  5.  
  6. Don't bother to create the Version file for the distribution any longer.
  7. Define SUN_FLT_BUG rather than just 'sun' to get the a fix for a floating
  8. point problem in ntpsubs; apparantly the DECSTATION 3100 also has the
  9. same problem.
  10. Removed some unused #defines.  Replaced MAXSTRATUM with NTP_INFIN per new
  11. spec.  The variable 'mode' in the peer structure has been renamed 'hmode'
  12. per the new spec.
  13. The variable 'mode' in the peer structure was renamed 'hmode'.  Add 
  14. poll_update() calls in a few places per Mills.  The receive() procedure is
  15. now table driven.  The poll_update procedure only randomized the timer
  16. when the interval changes.  If we lose synchronization, don't zap sys.stratum.
  17. Clean up the sanity_check() routine a bit.
  18. peer->mode has been renamed peer->hmode.  Drop PEER_FL_SYNC since the
  19. PEER_FL_CONFIG flag means much the same thing.
  20. Check for success sending query before trying to listen for answers.  Will 
  21. catch case of no server running and an ICMP port unreachable being returned.
  22. Add -l option to create a log scale plot of the compliance.  Fix the option
  23. handling code so that -S works again.  The drift compensation and compliance
  24. values are now scaled.
  25. From:
  26.  
  27. Description:
  28.  
  29. Repeat-By:
  30.  
  31. Fix:    From rn, say "| patch -p -N -d DIR", where DIR is your ntp source
  32.     directory.  Outside of rn, say "cd DIR; patch -p -N <thisarticle".
  33.     If you don't have the patch program, apply the following by hand,
  34.     or get patch (version 2.0, latest patchlevel).
  35.  
  36.     After patching:
  37.         make depend
  38.         make
  39.         make install
  40.  
  41.     If patch indicates that patchlevel is the wrong version, you may need
  42.     to apply one or more previous patches, or the patch may already
  43.     have been applied.  See the patchlevel.h file to find out what has or
  44.     has not been applied.  In any event, don't continue with the patch.
  45.  
  46.     If you are missing previous patches they can be obtained from me:
  47.  
  48.     Louis A. Mamakos
  49.     louie@trantor.umd.edu
  50.  
  51.     You can also get the patches via anonymous FTP from
  52.     trantor.umd.edu.
  53.  
  54. Index: patchlevel.h
  55. Prereq: 3
  56. 1c1
  57. < #define PATCHLEVEL 3
  58. ---
  59. > #define PATCHLEVEL 4
  60.  
  61. Index: Makefile
  62. *** Makefile.old    Wed Mar 29 12:47:37 1989
  63. --- Makefile    Wed Mar 29 12:47:38 1989
  64. ***************
  65. *** 1,6 ****
  66. ! # $Source: /usr/users/louie/ntp/RCS/Makefile,v $ $Revision: 3.4.1.2 $ $Date: 89/03/22 18:25:14 $
  67.   #
  68.   # $Log:    Makefile,v $
  69.   # Revision 3.4.1.2  89/03/22  18:25:14  louie
  70.   # patch3: Use new and improved RCS headers.
  71.   # 
  72. --- 1,12 ----
  73. ! # $Source: /usr/users/louie/ntp/RCS/Makefile,v $ $Revision: 3.4.1.3 $ $Date: 89/03/29 12:21:27 $
  74.   #
  75.   # $Log:    Makefile,v $
  76. + # Revision 3.4.1.3  89/03/29  12:21:27  louie
  77. + # Don't bother to create the Version file for the distribution any longer.
  78. + # Define SUN_FLT_BUG rather than just 'sun' to get the a fix for a floating
  79. + # point problem in ntpsubs; apparantly the DECSTATION 3100 also has the
  80. + # same problem.
  81. + # 
  82.   # Revision 3.4.1.2  89/03/22  18:25:14  louie
  83.   # patch3: Use new and improved RCS headers.
  84.   # 
  85. ***************
  86. *** 74,80 ****
  87.   DEFINES=
  88.   
  89.   # for Sun
  90. ! #DEFINES= -Dsun
  91.   
  92.   # for Ultrix 2.0/2.2/3.0
  93.   # don't forget to fix the broken definition of inet_addr in netdb.h
  94. --- 80,86 ----
  95.   DEFINES=
  96.   
  97.   # for Sun
  98. ! #DEFINES= -DSUN_FLT_BUG
  99.   
  100.   # for Ultrix 2.0/2.2/3.0
  101.   # don't forget to fix the broken definition of inet_addr in netdb.h
  102. ***************
  103. *** 169,178 ****
  104.       mv ntp.tar.Z /usr/ftp/pub/ntp.${VERS}/ntp-test.tar.Z
  105.   
  106.   ntp.tar.Z:    ${DIST}
  107. -     ident ${DIST} | grep Header | \
  108. -         sed -e 's/^ *.Header: //' -e 's/.\$$//' > Version
  109.       rm -f ntp.tar ntp.tar.Z
  110. !     tar cf ntp.tar Version ${DIST}
  111.       compress  ntp.tar
  112.   
  113.   
  114. --- 175,182 ----
  115.       mv ntp.tar.Z /usr/ftp/pub/ntp.${VERS}/ntp-test.tar.Z
  116.   
  117.   ntp.tar.Z:    ${DIST}
  118.       rm -f ntp.tar ntp.tar.Z
  119. !     tar cf ntp.tar ${DIST}
  120.       compress  ntp.tar
  121.   
  122.   
  123.  
  124. Index: ntp.h
  125. *** ntp.h.old    Wed Mar 29 12:47:42 1989
  126. --- ntp.h    Wed Mar 29 12:47:43 1989
  127. ***************
  128. *** 1,7 ****
  129. ! /* $Source: /usr/users/louie/ntp/RCS/ntp.h,v $ $Revision: 3.4.1.2 $ $Date: 89/03/22 18:28:18 $ */
  130.   
  131.   /*
  132.    *  $Log:    ntp.h,v $
  133.    * Revision 3.4.1.2  89/03/22  18:28:18  louie
  134.    * patch3: Use new RCS headers.
  135.    * 
  136. --- 1,12 ----
  137. ! /* $Source: /usr/users/louie/ntp/RCS/ntp.h,v $ $Revision: 3.4.1.3 $ $Date: 89/03/29 12:26:18 $ */
  138.   
  139.   /*
  140.    *  $Log:    ntp.h,v $
  141. +  * Revision 3.4.1.3  89/03/29  12:26:18  louie
  142. +  * Removed some unused #defines.  Replaced MAXSTRATUM with NTP_INFIN per new
  143. +  * spec.  The variable 'mode' in the peer structure has been renamed 'hmode'
  144. +  * per the new spec.
  145. +  * 
  146.    * Revision 3.4.1.2  89/03/22  18:28:18  louie
  147.    * patch3: Use new RCS headers.
  148.    * 
  149. ***************
  150. *** 71,79 ****
  151.   /*
  152.    *  Definitions for the masses
  153.    */
  154. - #define    MAXNAMELENGTH    80
  155.   #define    JAN_1970    2208988800    /* 1970 - 1900 in seconds */
  156. - #define    HIGH_BIT    0x80000000    /* sign bit on fixed point */
  157.   
  158.   /*
  159.    *  Daemon specific (ntpd.c)
  160. --- 76,82 ----
  161. ***************
  162. *** 100,107 ****
  163.   };
  164.   
  165.   #define    STRMCMP(a, cond, b) \
  166. !     (((a) == UNSPECIFIED ? MAXSTRATUM+1 : a) cond \
  167. !      ((b) == UNSPECIFIED ? MAXSTRATUM+1 : (b)))
  168.   
  169.   
  170.   /*
  171. --- 103,110 ----
  172.   };
  173.   
  174.   #define    STRMCMP(a, cond, b) \
  175. !     (((a) == UNSPECIFIED ? NTP_INFIN+1 : a) cond \
  176. !      ((b) == UNSPECIFIED ? NTP_INFIN+1 : (b)))
  177.   
  178.   
  179.   /*
  180. ***************
  181. *** 109,114 ****
  182. --- 112,118 ----
  183.    */
  184.   #define    NTP_VERSION    1
  185.   #define    NTP_PORT    123    /* for ref only (see /etc/services) */
  186. + #define    NTP_INFIN    15
  187.   #define    NTP_MAXAGE    86400
  188.   #define    NTP_MAXSKW    0.01    /* seconds */
  189.   #define    NTP_MINDIST    0.02    /* seconds */
  190. ***************
  191. *** 125,131 ****
  192.   #define    PEER_MAXDISP    64.0    /* Maximum dispersion  */
  193.   #define    PEER_THRESHOLD    0.5    /* dispersion threshold */
  194.   #define    PEER_FILTER    0.5    /* filter weight */
  195. - #define    PEER_SELECT    0.75    /* select weight */
  196.   
  197.   #if    XTAL == 0
  198.   #define    PEER_SHIFT    4
  199. --- 129,134 ----
  200. ***************
  201. *** 136,144 ****
  202.   #define    NTP_WINDOW_SHIFT_MASK 0xff
  203.   #define    PEER_SHIFT_MASK    0xff    /* 2^PEER_SHIFT - 1 */
  204.   
  205. - #define    NTP_MAXDELAY    65536.0    /* Maximum dispersion seconds*/
  206. - 
  207. - 
  208.   /*
  209.    *  5.1 Uniform Phase Adjustments
  210.    *  Clock parameters
  211. --- 139,144 ----
  212. ***************
  213. *** 261,267 ****
  214.    */
  215.   #define    UNSPECIFIED    0
  216.   #define    PRIM_REF    1    /* radio clock */
  217. - #define    MAXSTRATUM    15
  218.   #define    INFO_QUERY    62    /* **** THIS implementation dependent **** */
  219.   #define    INFO_REPLY    63    /* **** THIS implementation dependent **** */
  220.   
  221. --- 261,266 ----
  222. ***************
  223. *** 277,283 ****
  224.       int    flags;            /* local flags */
  225.   #define    PEER_FL_CONFIG        1
  226.   #define    PEER_FL_AUTHENABLE    2
  227. - #define    PEER_FL_SYNC        0x1000    /* allowed synchronize to this peer */
  228.   #define    PEER_FL_BCAST        0x2000    /* broadcast peer */
  229.   #define    PEER_FL_SELECTED    0x8000    /* actually used by query routine */
  230.   
  231. --- 276,281 ----
  232. ***************
  233. *** 284,290 ****
  234.       int    sock;            /* index into sockets to derive
  235.                          peer.dstadr and peer.dstport */
  236.       u_char    leap;            /* receive */
  237. !     u_char    mode;            /* receive */
  238.       u_char    stratum;        /* receive */
  239.       u_char    ppoll;            /* receive */
  240.       u_char    hpoll;            /* poll update */
  241. --- 282,288 ----
  242.       int    sock;            /* index into sockets to derive
  243.                          peer.dstadr and peer.dstport */
  244.       u_char    leap;            /* receive */
  245. !     u_char    hmode;            /* receive */
  246.       u_char    stratum;        /* receive */
  247.       u_char    ppoll;            /* receive */
  248.       u_char    hpoll;            /* poll update */
  249. ***************
  250. *** 304,310 ****
  251.        * first order offsets
  252.        */
  253.       struct    filter {
  254. !         short samples;
  255.           double offset[PEER_SHIFT];
  256.           double delay[PEER_SHIFT];
  257.       } filter;            /* filter, clear */
  258. --- 302,308 ----
  259.        * first order offsets
  260.        */
  261.       struct    filter {
  262. !         short samples;        /* <<local>> */
  263.           double offset[PEER_SHIFT];
  264.           double delay[PEER_SHIFT];
  265.       } filter;            /* filter, clear */
  266.  
  267. Index: ntp_proto.c
  268. *** ntp_proto.c.old    Wed Mar 29 12:47:49 1989
  269. --- ntp_proto.c    Wed Mar 29 12:47:51 1989
  270. ***************
  271. *** 1,5 ****
  272.   #ifndef    lint
  273. ! static char *rcsid = "$Source: /usr/users/louie/ntp/RCS/ntp_proto.c,v $ $Revision: 3.4.1.3 $ $Date: 89/03/22 18:32:31 $";
  274.   #endif
  275.   
  276.   /*
  277. --- 1,5 ----
  278.   #ifndef    lint
  279. ! static char *rcsid = "$Source: /usr/users/louie/ntp/RCS/ntp_proto.c,v $ $Revision: 3.4.1.4 $ $Date: 89/03/29 12:29:10 $";
  280.   #endif
  281.   
  282.   /*
  283. ***************
  284. *** 10,15 ****
  285. --- 10,22 ----
  286.    *
  287.    *
  288.    * $Log:    ntp_proto.c,v $
  289. +  * Revision 3.4.1.4  89/03/29  12:29:10  louie
  290. +  * The variable 'mode' in the peer structure was renamed 'hmode'.  Add 
  291. +  * poll_update() calls in a few places per Mills.  The receive() procedure is
  292. +  * now table driven.  The poll_update procedure only randomized the timer
  293. +  * when the interval changes.  If we lose synchronization, don't zap sys.stratum.
  294. +  * Clean up the sanity_check() routine a bit.
  295. +  * 
  296.    * Revision 3.4.1.3  89/03/22  18:32:31  louie
  297.    * patch3: Use new RCS headers.
  298.    * 
  299. ***************
  300. *** 123,129 ****
  301.       struct ntpdata *pkt = &ntpframe;
  302.       int i;
  303.   
  304. !     pkt->status = sys.leap | NTPVERSION_1 | peer->mode;
  305.       pkt->stratum = sys.stratum;
  306.       pkt->ppoll = peer->hpoll;
  307.       pkt->precision = (char) sys.precision;
  308. --- 130,136 ----
  309.       struct ntpdata *pkt = &ntpframe;
  310.       int i;
  311.   
  312. !     pkt->status = sys.leap | NTPVERSION_1 | peer->hmode;
  313.       pkt->stratum = sys.stratum;
  314.       pkt->ppoll = peer->hpoll;
  315.       pkt->precision = (char) sys.precision;
  316. ***************
  317. *** 214,225 ****
  318.           peer->valid++;
  319.       else {
  320.           clock_filter(peer, 0.0, 0.0);    /* call with invalid values */
  321. !         if (peer == sys.peer) {
  322. !             select_clock();        /* and try to reselect clock */
  323. !             if (peer != sys.peer && sys.peer != NULL)
  324. !                 poll_update(sys.peer, NTP_MINPOLL);
  325. !         }
  326.       }
  327.       peer->timer = 1<<(MAX(MIN(peer->ppoll, MIN(peer->hpoll, NTP_MAXPOLL)),
  328.                      NTP_MINPOLL));
  329.   
  330. --- 221,231 ----
  331.           peer->valid++;
  332.       else {
  333.           clock_filter(peer, 0.0, 0.0);    /* call with invalid values */
  334. !         select_clock();        /* and try to reselect clock */
  335. !         if (sys.peer != NULL)
  336. !             poll_update(sys.peer, NTP_MINPOLL);
  337.       }
  338. + 
  339.       peer->timer = 1<<(MAX(MIN(peer->ppoll, MIN(peer->hpoll, NTP_MAXPOLL)),
  340.                      NTP_MINPOLL));
  341.   
  342. ***************
  343. *** 240,245 ****
  344. --- 246,267 ----
  345.       struct ntp_peer *peer;
  346.       int peer_mode;
  347.   
  348. + #define    ACT_ERROR    1
  349. + #define    ACT_RECV    2
  350. + #define    ACT_XMIT    3
  351. + #define    ACT_PKT        4
  352. + 
  353. +     static char actions[5][5] = {
  354. + 
  355. +  /*      Sym Act   Sym Pas    Client     Server     Broadcast  |Host /       */
  356. +  /*      --------   --------  --------   ---------  ---------  |    / Peer   */
  357. +  /*                                                            ------------  */
  358. +     {ACT_PKT,  ACT_PKT,   ACT_RECV,  ACT_XMIT,  ACT_XMIT},    /* Sym Act   */
  359. +     {ACT_PKT,  ACT_ERROR, ACT_RECV,  ACT_ERROR, ACT_ERROR},    /* Sym Pas   */
  360. +     {ACT_XMIT, ACT_XMIT,  ACT_ERROR, ACT_XMIT,  ACT_XMIT},    /* Client    */
  361. +     {ACT_PKT,  ACT_ERROR, ACT_RECV,  ACT_ERROR, ACT_ERROR},    /* Server    */
  362. +     {ACT_PKT,  ACT_ERROR, ACT_RECV,  ACT_ERROR, ACT_ERROR}};/* Broadcast */
  363. + 
  364.       /* if we're only going to support NTP Version 2 then this stuff
  365.          isn't necessary, right? */
  366.   
  367. ***************
  368. *** 277,283 ****
  369.           make_new_peer(peer);
  370.           peer->src = *dst;
  371.           peer->sock = sock;
  372. !         peer->mode = MODE_SYM_PAS;
  373.           clear(peer);
  374.       } else
  375.           peer = check_peer(dst, sock);
  376. --- 299,305 ----
  377.           make_new_peer(peer);
  378.           peer->src = *dst;
  379.           peer->sock = sock;
  380. !         peer->hmode = MODE_SYM_PAS;
  381.           clear(peer);
  382.       } else
  383.           peer = check_peer(dst, sock);
  384. ***************
  385. *** 292,302 ****
  386.           peer->src = *dst;
  387.           peer->sock = sock;    /* remember which socket we heard 
  388.                          this from */
  389. !         peer->mode = MODE_SYM_PAS;
  390.           clear(peer);
  391.           enqueue(&peer_list, peer);
  392.       }
  393.   
  394.   #ifdef    BROADCAST_NTP
  395.       /*
  396.        *  Input frame matched a funny broadcast peer;  these peers only
  397. --- 314,333 ----
  398.           peer->src = *dst;
  399.           peer->sock = sock;    /* remember which socket we heard 
  400.                          this from */
  401. !         peer->hmode = MODE_SYM_PAS;
  402.           clear(peer);
  403.           enqueue(&peer_list, peer);
  404.       }
  405.   
  406. +     /* 
  407. +      *  "pre-configured" peers are initially assigned a socket index of
  408. +      *  -1, which means we don't know which interface we'll use to talk
  409. +      *  to them.  Once the first reply comes back, we'll update the
  410. +      *  peer structure
  411. +      */
  412. +     if (peer->sock == -1)
  413. +         peer->sock = sock;
  414. + 
  415.   #ifdef    BROADCAST_NTP
  416.       /*
  417.        *  Input frame matched a funny broadcast peer;  these peers only
  418. ***************
  419. *** 313,406 ****
  420.       }
  421.   #endif    /* BROADCAST_NTP */
  422.   
  423. !     /* 
  424. !      *  "pre-configured" peers are initially assigned a socket index of
  425. !      *  -1, which means we don't know which interface we'll use to talk
  426. !      *  to them.  Once the first reply comes back, we'll update the
  427. !      *  peer structure
  428. !      */
  429. !     if (peer->sock == -1)
  430. !         peer->sock = sock;
  431.   
  432. !     switch (peer_mode) {
  433. !     case MODE_SYM_PAS:
  434. !         if (peer->mode == MODE_SYM_PAS)
  435. !             goto receive_MODE_BROADCAST;    /* forgive me! */
  436.   
  437. !         /* * * * * NOTE FALL THRU * * * * */
  438. ! 
  439. !     case MODE_SYM_ACT:
  440. !         if (! STRMCMP(pkt->stratum, <=, sys.stratum)) {
  441. !             /*
  442. !              *  While not strictly in the spec, pre-configured
  443. !              *  peers will have their reachability kept, even 
  444. !              *  though they won't be selected.  We might as well
  445. !              *  since we've dedicated the resources to have these
  446. !              *  peers be persistant.
  447. !              */
  448. !             if (peer->flags & PEER_FL_CONFIG)
  449. !                 peer->reach |= 1;
  450. ! 
  451. !             switch (peer->mode) {
  452. !             case MODE_SYM_ACT:
  453. !             case MODE_CLIENT:
  454. !             case MODE_BROADCAST:
  455. !                 process_packet(dst, pkt, tvp, peer);
  456. !                 break;
  457. !             default:
  458. !                 process_packet(dst, pkt, tvp, peer);
  459. !                 poll_update(peer, peer->ppoll);
  460. !                 transmit(peer);
  461. !             }                
  462.               break;
  463.           }
  464. !         /* * * * * NOTE FALL THRU * * * * */
  465.   
  466. !     case MODE_SERVER:
  467. !         peer->reach |= 1;
  468. !         process_packet(dst, pkt, tvp, peer);
  469. !         break;
  470. ! 
  471. !     case MODE_CLIENT:
  472. !         if (peer->flags & PEER_FL_CONFIG)
  473. !             break;
  474. ! 
  475. !         switch (peer->mode) {
  476. !         case MODE_SYM_ACT:
  477. !         case MODE_CLIENT:
  478. !         case MODE_BROADCAST:
  479.               process_packet(dst, pkt, tvp, peer);
  480.               break;
  481. - 
  482. -         default:
  483. -             peer->mode = MODE_SERVER;
  484. -             process_packet(dst, pkt, tvp, peer);
  485. -             poll_update(peer, peer->ppoll);
  486. -             transmit(peer);
  487.           }
  488. !         break;
  489. ! 
  490. ! #ifdef    BROADCAST_NTP
  491. !     case MODE_BROADCAST:
  492. ! #endif
  493. !     receive_MODE_BROADCAST:    
  494. !         if (peer->flags & PEER_FL_CONFIG)
  495. !             break;
  496. ! 
  497.           process_packet(dst, pkt, tvp, peer);
  498. !         if (peer != &dummy_peer)
  499. !             demobilize(&peer_list, peer);
  500.           break;
  501.   
  502. - #ifdef    DEBUG
  503.       default:
  504. !         if (debug)
  505. !             printf("Unknown mode %d for peer at %s\n",
  506. !                    peer_mode, inet_ntoa(dst->sin_addr));
  507. ! #endif
  508.       }
  509.   }
  510.   
  511.   /* 3.4.3 Packet procedure */
  512.   void
  513.   process_packet(dst, pkt, tvp, peer)
  514. --- 344,403 ----
  515.       }
  516.   #endif    /* BROADCAST_NTP */
  517.   
  518. ! #if    0
  519. !     if ((peer->flags & PEER_FL_AUTHENABLE) &&
  520. !         pkt->mac) {
  521. !         /* verify computed crypto-checksum */
  522. !     }
  523. ! #endif
  524.   
  525. ! #ifdef    DEBUG
  526. !     if (peer_mode < MODE_SYM_ACT || peer_mode > MODE_BROADCAST ||
  527. !         peer->hmode < MODE_SYM_ACT || peer->hmode > MODE_BROADCAST) {
  528. !         printf("Bogus peer_mode or peer->hmode\n");
  529. !         abort();
  530. !     }
  531. ! #endif
  532.   
  533. !     switch (actions[peer_mode - 1][peer->hmode - 1]) {
  534. !     case ACT_RECV:
  535. !         if (!(peer->flags & PEER_FL_CONFIG == 0 &&
  536. !               STRMCMP(pkt->stratum, >, sys.stratum))) {
  537. !             peer->reach |= 1;
  538. !             process_packet(dst, pkt, tvp, peer);
  539.               break;
  540.           }
  541. !         /* Note fall-through */
  542. !     case ACT_ERROR:
  543. !         if ((peer != &dummy_peer) && (peer->flags & PEER_FL_CONFIG))
  544. !             demobilize(peer);
  545. !         return;
  546.   
  547. !     case ACT_PKT:
  548. !         if (!((peer->flags & PEER_FL_CONFIG == 0) &&
  549. !             STRMCMP(pkt->stratum, >, sys.stratum))) {
  550. !             peer->reach |= 1;
  551.               process_packet(dst, pkt, tvp, peer);
  552.               break;
  553.           }
  554. !         /* note fall-through */
  555. !     case ACT_XMIT:
  556.           process_packet(dst, pkt, tvp, peer);
  557. !         poll_update(peer, peer->ppoll);
  558. !         transmit(peer);
  559.           break;
  560.   
  561.       default:
  562. !         abort();
  563.       }
  564.   }
  565.   
  566. + #undef    ACT_ERROR
  567. + #undef    ACT_RECV
  568. + #undef    ACT_XMIT
  569. + #undef    ACT_PKT
  570. + 
  571. + 
  572.   /* 3.4.3 Packet procedure */
  573.   void
  574.   process_packet(dst, pkt, tvp, peer)
  575. ***************
  576. *** 508,518 ****
  577.   {
  578.       double temp;
  579.       extern int adj_logical();
  580. -     struct ntp_peer *old_selection = sys.peer;
  581.   
  582.       select_clock();
  583. ! 
  584. !     if (old_selection != sys.peer && sys.peer != NULL)
  585.           poll_update(sys.peer, NTP_MINPOLL);
  586.   
  587.       /*
  588. --- 505,513 ----
  589.   {
  590.       double temp;
  591.       extern int adj_logical();
  592.   
  593.       select_clock();
  594. !     if (sys.peer != NULL)
  595.           poll_update(sys.peer, NTP_MINPOLL);
  596.   
  597.       /*
  598. ***************
  599. *** 631,637 ****
  600.       peer->estdisp = PEER_MAXDISP;
  601.       for (i = 0; i < NTP_WINDOW; i++)
  602.           peer->filter.offset[i] = 0.0;
  603. !     peer->filter.samples = 0;
  604.       peer->reach = 0;
  605.       peer->valid = 0;
  606.       peer->org.int_part = peer->org.fraction = 0;
  607. --- 626,632 ----
  608.       peer->estdisp = PEER_MAXDISP;
  609.       for (i = 0; i < NTP_WINDOW; i++)
  610.           peer->filter.offset[i] = 0.0;
  611. !     peer->filter.samples = 0;    /* Implementation specific */
  612.       peer->reach = 0;
  613.       peer->valid = 0;
  614.       peer->org.int_part = peer->org.fraction = 0;
  615. ***************
  616. *** 639,644 ****
  617. --- 634,641 ----
  618.       peer->xmt.int_part = peer->xmt.fraction = 0;
  619.       poll_update(peer, NTP_MINPOLL);
  620.       select_clock();
  621. +     if (sys.peer != NULL)
  622. +         poll_update(sys.peer, NTP_MINPOLL);
  623.   }
  624.   
  625.   
  626. ***************
  627. *** 660,665 ****
  628. --- 657,666 ----
  629.       interval = 1 << (MAX(MIN(peer->ppoll, MIN(peer->hpoll, NTP_MAXPOLL)),
  630.                  NTP_MINPOLL));
  631.   
  632. +     if (interval == peer->timer)
  633. +         return;
  634. + 
  635. +     /* only randomize when poll interval changes */
  636.       if (interval < peer->timer)
  637.           peer->timer = interval;
  638.   
  639. ***************
  640. *** 745,752 ****
  641.   
  642.           peer->estdelay = delay[0];
  643.           peer->estoffset = offset[0];
  644. !     } else
  645. !         peer->estoffset = peer->estdelay = 0.0;
  646.   
  647.       temp = 0.0;
  648.       w = 1.0;
  649. --- 746,752 ----
  650.   
  651.           peer->estdelay = delay[0];
  652.           peer->estoffset = offset[0];
  653. !     }
  654.   
  655.       temp = 0.0;
  656.       w = 1.0;
  657. ***************
  658. *** 821,828 ****
  659.               printf("select_clock: no candidates\n");
  660.   #endif
  661.           sys.peer = NULL;
  662. !         sys.stratum = 0;
  663. !         sys.refid = htonl('N'<<24 | 'O'<<16 | 'N'<<8 | 'E');
  664.           return;
  665.       }
  666.   
  667. --- 821,832 ----
  668.               printf("select_clock: no candidates\n");
  669.   #endif
  670.           sys.peer = NULL;
  671. !         /*
  672. !          * leave sys.stratum and sys.refid intact after losing 
  673. !          * reachability to all clocks.  After 24 hours, we'll
  674. !          * set the alarm condition if we didn't get any clock
  675. !          * updates.
  676. !          */
  677.           return;
  678.       }
  679.   
  680. ***************
  681. *** 984,1009 ****
  682.           printf("Checking peer %s stratum %d\n",
  683.                  inet_ntoa(peer->src.sin_addr), peer->stratum);
  684.   #endif
  685. !     /* are we allowed to sync to this clock? */
  686. !     if ((peer->flags & PEER_FL_SYNC) == 0)
  687.           return(0);
  688.   
  689. !     /* is peer reachable?        XXX */
  690. !     if (peer->reach == 0)
  691.           return(0);
  692.   
  693. !     /* is peer synchronized? */
  694. !     if (peer->leap == ALARM)
  695. !         return(0);
  696.   
  697. -     /* is peer worse off than us?    XXX */
  698. -     if (STRMCMP(peer->stratum, >, sys.stratum) ||
  699. -         (peer->stratum >= MAXSTRATUM))
  700. -         return(0);
  701. - 
  702. -     /* 4.2 "if peer.stratum is greater than one (synchronized via NTP),
  703. -        peer.refid must not match peer.dstadr" */
  704. - 
  705.       if (peer->stratum > 1) {
  706.           register int i;
  707.           for (i = 1; i < nintf; i++)
  708. --- 988,1005 ----
  709.           printf("Checking peer %s stratum %d\n",
  710.                  inet_ntoa(peer->src.sin_addr), peer->stratum);
  711.   #endif
  712. !     /* Sanity check 0. ?? */
  713. !     if (!(peer->flags & PEER_FL_CONFIG))
  714.           return(0);
  715.   
  716. !     /* Sanity check 1. */
  717. !     if (peer->stratum <= 0 || peer->stratum >= NTP_INFIN)
  718.           return(0);
  719.   
  720. !     /* Sanity check 2.
  721. !        if peer.stratum is greater than one (synchronized via NTP),
  722. !        peer.refid must not match peer.dstadr */
  723.   
  724.       if (peer->stratum > 1) {
  725.           register int i;
  726.           for (i = 1; i < nintf; i++)
  727. ***************
  728. *** 1011,1035 ****
  729.                   return (0);
  730.       }
  731.   
  732. !     /* 
  733. !        4.2. "Another check requires that both peer.estdelay and
  734.          peer.estdisp to be less than NTP_MAXWGT, which insures that the
  735. !        filter register at least half full, yet avoids using data
  736. !        from very noisy associations or broken implementations."
  737. !     */
  738.       if (peer->estdisp > (float)NTP_MAXWGT || 
  739.           peer->estdelay > (float)NTP_MAXWGT)
  740.           return(0);
  741.   
  742. !     /*  4.2 "A third check requires that the interval since the peer
  743. !         clock was last updated be less than NTP_MAXAGS */
  744.   
  745. !     if ((ul_fixed_to_double(&peer->org)
  746.            - ul_fixed_to_double(&peer->reftime)) >= NTP_MAXAGE)
  747. -         return(0);
  748. - 
  749. -     /* is dispersion reasonable? */
  750. -     if (s_fixed_to_double(&peer->dispersion) > PEER_THRESHOLD)
  751.           return(0);
  752.   
  753.   #ifdef    DEBUG
  754. --- 1007,1030 ----
  755.                   return (0);
  756.       }
  757.   
  758. !     /* Sanity check 3.
  759. !        Both peer.estdelay and
  760.          peer.estdisp to be less than NTP_MAXWGT, which insures that the
  761. !        filter register at least half full, yet avoids using data from
  762. !        very noisy associations or broken implementations.      */
  763.       if (peer->estdisp > (float)NTP_MAXWGT || 
  764.           peer->estdelay > (float)NTP_MAXWGT)
  765.           return(0);
  766.   
  767. !     /*  Sanity check 4.
  768. !         The peer clock must be synchronized... and the interval since
  769. !         the peer clock was last updated satisfy
  770.   
  771. !         peer.org - peer.reftime < NTP.MAXAGS
  772. !      */
  773. !     if (peer->leap == ALARM ||
  774. !         (ul_fixed_to_double(&peer->org)
  775.            - ul_fixed_to_double(&peer->reftime)) >= NTP_MAXAGE)
  776.           return(0);
  777.   
  778.   #ifdef    DEBUG
  779.  
  780. Index: ntpd.c
  781. *** ntpd.c.old    Wed Mar 29 12:48:00 1989
  782. --- ntpd.c    Wed Mar 29 12:48:03 1989
  783. ***************
  784. *** 1,9 ****
  785.   #ifndef    lint
  786. ! static char *rcsid = "$Source: /usr/users/louie/ntp/RCS/ntpd.c,v $ $Revision: 3.4.1.3 $ $Date: 89/03/22 18:29:41 $";
  787.   #endif    lint
  788.   
  789.   /*
  790.    *  $Log:    ntpd.c,v $
  791.    * Revision 3.4.1.3  89/03/22  18:29:41  louie
  792.    * patch3: Use new RCS headers.
  793.    * 
  794. --- 1,13 ----
  795.   #ifndef    lint
  796. ! static char *rcsid = "$Source: /usr/users/louie/ntp/RCS/ntpd.c,v $ $Revision: 3.4.1.4 $ $Date: 89/03/29 12:30:46 $";
  797.   #endif    lint
  798.   
  799.   /*
  800.    *  $Log:    ntpd.c,v $
  801. +  * Revision 3.4.1.4  89/03/29  12:30:46  louie
  802. +  * peer->mode has been renamed peer->hmode.  Drop PEER_FL_SYNC since the
  803. +  * PEER_FL_CONFIG flag means much the same thing.
  804. +  * 
  805.    * Revision 3.4.1.3  89/03/22  18:29:41  louie
  806.    * patch3: Use new RCS headers.
  807.    * 
  808. ***************
  809. *** 238,249 ****
  810.           setlogmask(LOG_UPTO(LOG_INFO));
  811.   #endif    /* LOG_DAEMON */
  812.   
  813. !     syslog(LOG_NOTICE, "%s version $Revision: 3.4.1.3 $", prog_name);
  814.       syslog(LOG_NOTICE, "patchlevel %d", PATCHLEVEL);
  815.   
  816.   #ifdef    DEBUG
  817.       if (debug)
  818. !         printf("%s version $Revision: 3.4.1.3 $ patchlevel %d\n",
  819.                  prog_name, PATCHLEVEL);
  820.   #endif
  821.       (void) setpriority(PRIO_PROCESS, 0, -10);
  822. --- 242,253 ----
  823.           setlogmask(LOG_UPTO(LOG_INFO));
  824.   #endif    /* LOG_DAEMON */
  825.   
  826. !     syslog(LOG_NOTICE, "%s version $Revision: 3.4.1.4 $", prog_name);
  827.       syslog(LOG_NOTICE, "patchlevel %d", PATCHLEVEL);
  828.   
  829.   #ifdef    DEBUG
  830.       if (debug)
  831. !         printf("%s version $Revision: 3.4.1.4 $ patchlevel %d\n",
  832.                  prog_name, PATCHLEVEL);
  833.   #endif
  834.       (void) setpriority(PRIO_PROCESS, 0, -10);
  835. ***************
  836. *** 455,461 ****
  837.       peer->src.sin_family = AF_INET;
  838.       peer->src.sin_port = 0;
  839.       peer->src.sin_addr.s_addr = 0;
  840. !     peer->mode = MODE_SYM_PAS;    /* default: symmetric passive mode */
  841.       peer->flags = 0;
  842.       peer->timer = 1 << NTP_MINPOLL;
  843.       peer->stopwatch = 0;
  844. --- 459,465 ----
  845.       peer->src.sin_family = AF_INET;
  846.       peer->src.sin_port = 0;
  847.       peer->src.sin_addr.s_addr = 0;
  848. !     peer->hmode = MODE_SYM_PAS;    /* default: symmetric passive mode */
  849.       peer->flags = 0;
  850.       peer->timer = 1 << NTP_MINPOLL;
  851.       peer->stopwatch = 0;
  852. ***************
  853. *** 469,475 ****
  854.       peer->filter.samples = 0;
  855.       for (i = 0; i < NTP_WINDOW; i++) {
  856.           peer->filter.offset[i] = 0.0;
  857. !         peer->filter.delay[i] = NTP_MAXDELAY;
  858.       }
  859.       peer->pkt_sent = 0;
  860.       peer->pkt_rcvd = 0;
  861. --- 473,479 ----
  862.       peer->filter.samples = 0;
  863.       for (i = 0; i < NTP_WINDOW; i++) {
  864.           peer->filter.offset[i] = 0.0;
  865. !         peer->filter.delay[i] = 0.0;
  866.       }
  867.       peer->pkt_sent = 0;
  868.       peer->pkt_rcvd = 0;
  869. ***************
  870. *** 615,621 ****
  871.           }
  872.   #endif
  873.           next = peer->next;
  874. !         if (peer->reach != 0 || peer->mode != MODE_SERVER) {
  875.               peer->stopwatch +=(1<<CLOCK_ADJ);
  876.               if (peer->timer <= peer->stopwatch) {
  877.                   transmit(peer);
  878. --- 619,625 ----
  879.           }
  880.   #endif
  881.           next = peer->next;
  882. !         if (peer->reach != 0 || peer->hmode != MODE_SERVER) {
  883.               peer->stopwatch +=(1<<CLOCK_ADJ);
  884.               if (peer->timer <= peer->stopwatch) {
  885.                   transmit(peer);
  886. ***************
  887. *** 663,669 ****
  888.   {
  889.       struct sockaddr_in sin;
  890.       char ref_clock[5];
  891. !     char name[MAXNAMELENGTH + 1];
  892.       FILE *fp;
  893.       int error = FALSE, c;
  894.       struct ntp_peer *peer;
  895. --- 667,673 ----
  896.   {
  897.       struct sockaddr_in sin;
  898.       char ref_clock[5];
  899. !     char name[81];
  900.       FILE *fp;
  901.       int error = FALSE, c;
  902.       struct ntp_peer *peer;
  903. ***************
  904. *** 750,756 ****
  905.               }
  906.               make_new_peer(peer);
  907.               peer->flags = PEER_FL_BCAST;
  908. !             peer->mode = MODE_BROADCAST;
  909.               peer->src = addrs[i].bcast;
  910.               peer->sock = i;
  911.   #endif    /* BROADCAST_NTP */
  912. --- 754,760 ----
  913.               }
  914.               make_new_peer(peer);
  915.               peer->flags = PEER_FL_BCAST;
  916. !             peer->hmode = MODE_BROADCAST;
  917.               peer->src = addrs[i].bcast;
  918.               peer->sock = i;
  919.   #endif    /* BROADCAST_NTP */
  920. ***************
  921. *** 791,811 ****
  922.                           peer->flags = PEER_FL_CONFIG;
  923.                           switch (mode) {
  924.                           case MODE_SYM_ACT:    /* "peer" */
  925. !                             peer->mode = MODE_SYM_ACT;
  926. !                             /* mark peer as sync-able */
  927. !                             peer->flags |= PEER_FL_SYNC;
  928.                               peer->stopwatch = stagger;
  929.                               stagger += (1<<CLOCK_ADJ);
  930.                               break;
  931.                           case MODE_CLIENT:    /* "server" */
  932. !                             peer->mode = MODE_CLIENT;
  933. !                             peer->flags |= PEER_FL_SYNC;
  934.                               peer->stopwatch = stagger;
  935.                               stagger += (1<<CLOCK_ADJ);
  936.                               break;
  937.                           case MODE_SYM_PAS:    /* "passive" */
  938. !                             peer->mode = MODE_SYM_PAS;
  939. !                             peer->flags |= PEER_FL_SYNC;
  940.                               break;
  941.                           default:
  942.                               printf("can't happen\n");
  943. --- 795,811 ----
  944.                           peer->flags = PEER_FL_CONFIG;
  945.                           switch (mode) {
  946.                           case MODE_SYM_ACT:    /* "peer" */
  947. !                             peer->hmode = MODE_SYM_ACT;
  948.                               peer->stopwatch = stagger;
  949.                               stagger += (1<<CLOCK_ADJ);
  950.                               break;
  951.                           case MODE_CLIENT:    /* "server" */
  952. !                             peer->hmode = MODE_CLIENT;
  953.                               peer->stopwatch = stagger;
  954.                               stagger += (1<<CLOCK_ADJ);
  955.                               break;
  956.                           case MODE_SYM_PAS:    /* "passive" */
  957. !                             peer->hmode = MODE_SYM_PAS;
  958.                               break;
  959.                           default:
  960.                               printf("can't happen\n");
  961. ***************
  962. *** 821,827 ****
  963.                                      inet_ntoa(peer->src.sin_addr),
  964.                                      ntohs(peer->src.sin_port),
  965.                                      peer->src.sin_family,
  966. !                                    peer->mode);
  967.   #endif
  968.                       }
  969.                   } else {
  970. --- 821,827 ----
  971.                                      inet_ntoa(peer->src.sin_addr),
  972.                                      ntohs(peer->src.sin_port),
  973.                                      peer->src.sin_family,
  974. !                                    peer->hmode);
  975.   #endif
  976.                       }
  977.                   } else {
  978.  
  979. Index: ntpdc.c
  980. *** ntpdc.c.old    Wed Mar 29 12:48:09 1989
  981. --- ntpdc.c    Wed Mar 29 12:48:11 1989
  982. ***************
  983. *** 1,9 ****
  984.   #ifndef    lint
  985. ! static char *RCSid = "$Source: /usr/users/louie/ntp/RCS/ntpdc.c,v $ $Revision: 3.4.1.3 $ $Date: 89/03/22 18:29:53 $";
  986.   #endif
  987.   
  988.   /*
  989.    * $Log:    ntpdc.c,v $
  990.    * Revision 3.4.1.3  89/03/22  18:29:53  louie
  991.    * patch3: Use new RCS headers.
  992.    * 
  993. --- 1,13 ----
  994.   #ifndef    lint
  995. ! static char *RCSid = "$Source: /usr/users/louie/ntp/RCS/ntpdc.c,v $ $Revision: 3.4.1.4 $ $Date: 89/03/29 12:41:56 $";
  996.   #endif
  997.   
  998.   /*
  999.    * $Log:    ntpdc.c,v $
  1000. +  * Revision 3.4.1.4  89/03/29  12:41:56  louie
  1001. +  * Check for success sending query before trying to listen for answers.  Will 
  1002. +  * catch case of no server running and an ICMP port unreachable being returned.
  1003. +  * 
  1004.    * Revision 3.4.1.3  89/03/22  18:29:53  louie
  1005.    * patch3: Use new RCS headers.
  1006.    * 
  1007. ***************
  1008. *** 130,135 ****
  1009. --- 134,140 ----
  1010.       }
  1011.       if (argc > 1)
  1012.           printf("--- %s ---\n", *argv);
  1013. + 
  1014.       while (argc > 0) {
  1015.           /*
  1016.            * Get a new socket each time - this will cause us to ignore
  1017. ***************
  1018. *** 145,152 ****
  1019.               fprintf(stderr, "setsockopt SO_RCVBUF\n");
  1020.           }
  1021.   #endif
  1022. !         query(*argv);
  1023. !         answer();
  1024.           close(s);
  1025.           argv++;
  1026.           if (argc-- > 1)
  1027. --- 150,157 ----
  1028.               fprintf(stderr, "setsockopt SO_RCVBUF\n");
  1029.           }
  1030.   #endif
  1031. !         if (query(*argv))
  1032. !             answer(*argv);
  1033.           close(s);
  1034.           argv++;
  1035.           if (argc-- > 1)
  1036. ***************
  1037. *** 155,161 ****
  1038.   
  1039.   }
  1040.   
  1041. ! answer() {
  1042.       register struct ntpinfo *msg = (struct ntpinfo *) packet;
  1043.       register struct clockinfo *n;
  1044.       struct sockaddr_in from;
  1045. --- 160,168 ----
  1046.   
  1047.   }
  1048.   
  1049. ! answer(host)
  1050. !     char *host;
  1051. ! {
  1052.       register struct ntpinfo *msg = (struct ntpinfo *) packet;
  1053.       register struct clockinfo *n;
  1054.       struct sockaddr_in from;
  1055. ***************
  1056. *** 184,192 ****
  1057.                    (struct sockaddr *)&from, &fromlen)) <= 0) {
  1058.               if (cc == 0 || errno == EINTR)
  1059.                   continue;
  1060. !             perror("recvfrom");
  1061.               (void) close(s);
  1062. !             exit(1);
  1063.           }
  1064.           FD_SET(s, &bits);
  1065.   
  1066. --- 191,200 ----
  1067.                    (struct sockaddr *)&from, &fromlen)) <= 0) {
  1068.               if (cc == 0 || errno == EINTR)
  1069.                   continue;
  1070. !             fflush(stdout);
  1071. !             perror(host);
  1072.               (void) close(s);
  1073. !             return;
  1074.           }
  1075.           FD_SET(s, &bits);
  1076.   
  1077. ***************
  1078. *** 228,234 ****
  1079.           printf("Timed out waiting for replies\n");
  1080.   }
  1081.   
  1082. ! 
  1083.   query(host)
  1084.       char *host;
  1085.   {
  1086. --- 236,242 ----
  1087.           printf("Timed out waiting for replies\n");
  1088.   }
  1089.   
  1090. ! int
  1091.   query(host)
  1092.       char *host;
  1093.   {
  1094. ***************
  1095. *** 246,252 ****
  1096.           hp = gethostbyname(host);
  1097.           if (hp == 0) {
  1098.               fprintf(stderr,"%s: unknown\n", host);
  1099. !             exit(1);
  1100.           }
  1101.           bcopy(hp->h_addr, (char *) &watcher.sin_addr, hp->h_length);
  1102.       }
  1103. --- 254,260 ----
  1104.           hp = gethostbyname(host);
  1105.           if (hp == 0) {
  1106.               fprintf(stderr,"%s: unknown\n", host);
  1107. !             return 0;
  1108.           }
  1109.           bcopy(hp->h_addr, (char *) &watcher.sin_addr, hp->h_length);
  1110.       }
  1111. ***************
  1112. *** 260,271 ****
  1113.       msg->stratum = INFO_QUERY;
  1114.       if (connect(s, (struct sockaddr *) &watcher, sizeof(watcher))) {
  1115.           perror("connect");
  1116. !         exit(1);
  1117.       }
  1118.       if (send(s, packet, sizeof(struct ntpdata), 0) < 0) {
  1119.           perror("send");
  1120. !         exit(2);
  1121.       }
  1122.   }
  1123.   
  1124.   timeout()
  1125. --- 268,280 ----
  1126.       msg->stratum = INFO_QUERY;
  1127.       if (connect(s, (struct sockaddr *) &watcher, sizeof(watcher))) {
  1128.           perror("connect");
  1129. !         return 0;
  1130.       }
  1131.       if (send(s, packet, sizeof(struct ntpdata), 0) < 0) {
  1132.           perror("send");
  1133. !         return 0;
  1134.       }
  1135. +     return 1;
  1136.   }
  1137.   
  1138.   timeout()
  1139. ***************
  1140. *** 290,296 ****
  1141.       del = (long) ntohl(n->estdelay);    /* leave in milliseconds */
  1142.       off = (long) ntohl(n->estoffset);    /* leave in milliseconds */
  1143.       c = ' ';
  1144. !     if (ntohs(n->flags))
  1145.           c = '-';        /* mark pre-configured */
  1146.       if (ntohs(n->flags) & PEER_FL_SELECTED)
  1147.           c = '*';        /* mark peer selection */
  1148. --- 299,305 ----
  1149.       del = (long) ntohl(n->estdelay);    /* leave in milliseconds */
  1150.       off = (long) ntohl(n->estoffset);    /* leave in milliseconds */
  1151.       c = ' ';
  1152. !     if (ntohs(n->flags) & PEER_FL_CONFIG)
  1153.           c = '-';        /* mark pre-configured */
  1154.       if (ntohs(n->flags) & PEER_FL_SELECTED)
  1155.           c = '*';        /* mark peer selection */
  1156. ***************
  1157. *** 331,339 ****
  1158.              ntohs(n->flags),
  1159.              n->leap);
  1160.       if (n->stratum == 1 || n->stratum == 0) {
  1161. !         u_long TmP;
  1162. ! 
  1163. !         (void) strncpy(ref_clock, (char *) &TmP, 4);
  1164.           ref_clock[4] = '\0';
  1165.           printf("Reference clock ID: %s", ref_clock);
  1166.       } else {
  1167. --- 340,346 ----
  1168.              ntohs(n->flags),
  1169.              n->leap);
  1170.       if (n->stratum == 1 || n->stratum == 0) {
  1171. !         (void) strncpy(ref_clock, (char *) &n->refid, 4);
  1172.           ref_clock[4] = '\0';
  1173.           printf("Reference clock ID: %s", ref_clock);
  1174.       } else {
  1175.  
  1176. Index: ntpsubs.c
  1177. *** ntpsubs.c.old    Wed Mar 29 12:48:14 1989
  1178. --- ntpsubs.c    Wed Mar 29 12:48:15 1989
  1179. ***************
  1180. *** 1,9 ****
  1181.   #ifndef    lint
  1182. ! static char *RCSid = "$Source: /usr/users/louie/ntp/RCS/ntpsubs.c,v $ $Revision: 3.4.1.1 $ $Date: 89/03/22 18:32:19 $";
  1183.   #endif    lint
  1184.   
  1185.   /*
  1186.    *  $Log:    ntpsubs.c,v $
  1187.    * Revision 3.4.1.1  89/03/22  18:32:19  louie
  1188.    * patch3: Use new RCS headers.
  1189.    * 
  1190. --- 1,13 ----
  1191.   #ifndef    lint
  1192. ! static char *RCSid = "$Source: /usr/users/louie/ntp/RCS/ntpsubs.c,v $ $Revision: 3.4.1.2 $ $Date: 89/03/29 12:46:02 $";
  1193.   #endif    lint
  1194.   
  1195.   /*
  1196.    *  $Log:    ntpsubs.c,v $
  1197. +  * Revision 3.4.1.2  89/03/29  12:46:02  louie
  1198. +  * Check for success sending query before trying to listen for answers.  Will 
  1199. +  * catch case of no server running and an ICMP port unreachable being returned.
  1200. +  * 
  1201.    * Revision 3.4.1.1  89/03/22  18:32:19  louie
  1202.    * patch3: Use new RCS headers.
  1203.    * 
  1204. ***************
  1205. *** 181,187 ****
  1206.       results in the value 2^31.  Neither 4.2bsd nor VMS have this
  1207.       problem.  Reported it to Bob O'Brien of SMI
  1208.   */
  1209. ! #ifdef    sun
  1210.   tstamp(stampp, tvp)
  1211.       struct l_fixedpt *stampp;
  1212.       struct timeval *tvp;
  1213. --- 185,191 ----
  1214.       results in the value 2^31.  Neither 4.2bsd nor VMS have this
  1215.       problem.  Reported it to Bob O'Brien of SMI
  1216.   */
  1217. ! #ifdef    SUN_FLT_BUG
  1218.   tstamp(stampp, tvp)
  1219.       struct l_fixedpt *stampp;
  1220.       struct timeval *tvp;
  1221. ***************
  1222. *** 202,208 ****
  1223.       stampp->int_part = ntohl((u_long) (JAN_1970 + tvp->tv_sec));
  1224.       stampp->fraction = ntohl((u_long) ((float) tvp->tv_usec * 4294.967295));
  1225.   }
  1226. ! #endif    sun
  1227.   
  1228.   /*
  1229.    * ntoa is similar to inet_ntoa, but cycles through a set of 8 buffers
  1230. --- 206,212 ----
  1231.       stampp->int_part = ntohl((u_long) (JAN_1970 + tvp->tv_sec));
  1232.       stampp->fraction = ntohl((u_long) ((float) tvp->tv_usec * 4294.967295));
  1233.   }
  1234. ! #endif
  1235.   
  1236.   /*
  1237.    * ntoa is similar to inet_ntoa, but cycles through a set of 8 buffers
  1238.  
  1239. Index: stat.pl
  1240. Prereq: 3.4.1.2
  1241. *** stat.pl.old    Wed Mar 29 12:48:18 1989
  1242. --- stat.pl    Wed Mar 29 12:48:19 1989
  1243. ***************
  1244. *** 1,9 ****
  1245.   #!/usr/bin/perl  
  1246. ! # $Source: /usr/users/louie/ntp/RCS/stat.pl,v $ $Revision: 3.4.1.2 $ $Date: 89/03/22 18:32:28 $
  1247.   #
  1248.   #  Make plots from ntpd syslog messages.  Invoked as:
  1249.   #
  1250. ! #   stat.pl [-o outputfile] [-i interval] [-t termtype] [-S] < logmessages
  1251.   #
  1252.   #  Where interval is the number of hours per plot, default is all data on
  1253.   #  on set of plots.
  1254. --- 1,9 ----
  1255.   #!/usr/bin/perl  
  1256. ! # $Source: /usr/users/louie/ntp/RCS/stat.pl,v $ $Revision: 3.4.1.3 $ $Date: 89/03/29 12:47:32 $
  1257.   #
  1258.   #  Make plots from ntpd syslog messages.  Invoked as:
  1259.   #
  1260. ! #   stat.pl [-o outputfile] [-i interval] [-t termtype] [-S] [-l] < logmessages
  1261.   #
  1262.   #  Where interval is the number of hours per plot, default is all data on
  1263.   #  on set of plots.
  1264. ***************
  1265. *** 14,19 ****
  1266. --- 14,21 ----
  1267.   #  output file is the name of the file which will receive plot data.  The
  1268.   #  default is "stats.plot".
  1269.   #
  1270. + #  The -l option will also create log scale plots.
  1271. + #
  1272.   #  The -S option will "save" the intermedite data files, which are normally
  1273.   #  deleted.
  1274.   #
  1275. ***************
  1276. *** 47,56 ****
  1277.   $clocks = 1;
  1278.   $clk{'UNSYNCED'} = 0;
  1279.   
  1280. ! do Getopt('tiSo');
  1281.   
  1282.   if ($opt_h) {
  1283. !    die "Usage: $scriptfile [-o outputfile] [-i interval] [-t termtype] [-S] < logmessages\n";
  1284.   }
  1285.   
  1286.   if ($opt_t) {
  1287. --- 49,58 ----
  1288.   $clocks = 1;
  1289.   $clk{'UNSYNCED'} = 0;
  1290.   
  1291. ! do Getopt('tio');
  1292.   
  1293.   if ($opt_h) {
  1294. !    die "Usage: $scriptfile [-o outputfile] [-i interval] [-t termtype] [-l] [-S] < logmessages\n";
  1295.   }
  1296.   
  1297.   if ($opt_t) {
  1298. ***************
  1299. *** 92,98 ****
  1300.               $clk{$in[8]} = $clocks++;
  1301.           }
  1302.           $t = $t - $start;
  1303. !         printf CLK "%f %f\n",$t,$clk{$in[8]};
  1304.   
  1305.       }
  1306.       if (/.* ntpd\[[0-9]*\]: adjust:/) {
  1307. --- 94,100 ----
  1308.               $clk{$in[8]} = $clocks++;
  1309.           }
  1310.           $t = $t - $start;
  1311. !         print CLK $t,$clk{$in[8]},"\n";
  1312.   
  1313.       }
  1314.       if (/.* ntpd\[[0-9]*\]: adjust:/) {
  1315. ***************
  1316. *** 113,120 ****
  1317.           # offset=11 drift=13 compliance=15
  1318.   
  1319.           print OFF $t, " ", $in[11],"\n";
  1320. !         print DRIFT $t," ",$in[13],"\n";
  1321. !         print COMP $t," ",$in[15],"\n";
  1322.       }
  1323.   }
  1324.   
  1325. --- 115,129 ----
  1326.           # offset=11 drift=13 compliance=15
  1327.   
  1328.           print OFF $t, " ", $in[11],"\n";
  1329. !         #
  1330. !         #  Scale the drift compensation by 256.0 to convert to PPM.
  1331. !         #
  1332. !         print DRIFT $t," ", $in[13]/256.0, "\n";
  1333. ! 
  1334. !         #
  1335. !         #  Scale compliance by T (2**18)
  1336. !         #
  1337. !         print COMP $t," ",$in[15] * 2**18, "\n";
  1338.       }
  1339.   }
  1340.   
  1341. ***************
  1342. *** 123,129 ****
  1343.   } else {
  1344.       $last = int($t);
  1345.   }
  1346. ! printf "%d records spanning %4.2f hours.\n", $recs, $t;
  1347.   
  1348.   close OFF;
  1349.   close DRIFT;
  1350. --- 132,138 ----
  1351.   } else {
  1352.       $last = int($t);
  1353.   }
  1354. ! print "$recs records spanning %t hours.\n";
  1355.   
  1356.   close OFF;
  1357.   close DRIFT;
  1358. ***************
  1359. *** 169,174 ****
  1360. --- 178,188 ----
  1361.       print TMP "set autoscale\n";
  1362.       print TMP "plot [$start:$end] ",'"stats.drift"'," with lines\n";
  1363.       print TMP "plot [$start:$end] ",'"stats.comp"'," with lines\n";
  1364. +     if ($opt_l) {
  1365. +         print TMP "set logscale y\n";
  1366. +         print TMP "plot [$start:$end] ",'"stats.comp"'," with lines\n";
  1367. +         print TMP "set nologscale\n";
  1368. +     }
  1369.       print TMP "plot [$start:$end] [-0.1:0.1] ",
  1370.           '"stats.off"'," with lines\n";
  1371.       print TMP "plot [$start:$end] [0:$clocks]",
  1372. ***************
  1373. *** 192,198 ****
  1374.       unlink "stats.clk";
  1375.   }
  1376.   
  1377. ! ;# $Header: /usr/users/louie/ntp/RCS/stat.pl,v 3.4.1.2 89/03/22 18:32:28 louie Exp $
  1378.   
  1379.   ;# Process single-character switches with switch clustering.  Pass one argument
  1380.   ;# which is a string containing all switches that take an argument.  For each
  1381. --- 206,212 ----
  1382.       unlink "stats.clk";
  1383.   }
  1384.   
  1385. ! ;# $Header: /usr/users/louie/ntp/RCS/stat.pl,v 3.4.1.3 89/03/29 12:47:32 louie Exp Locker: louie $
  1386.   
  1387.   ;# Process single-character switches with switch clustering.  Pass one argument
  1388.   ;# which is a string containing all switches that take an argument.  For each
  1389.